package cn.ac.iie.di.ban.ycl.cleaner.common;

/**
 * @author zmc <zhangmingcheng@iie.ac.cn>
 * @date 2016-2-24 13:48:56
 * @version V1.0
 * @desc
 */
public final class Constants {

	private Constants() {
	}
	public static final String RECEIVER_THREAD_NUM = "receiver.thread.num";
	public static final String RECEIVER_MQ_NAMESERVER = "receiver.rocketmq.nameserver";
	public static final String RECEIVER_MQ_READ_TOPIC = "receiver.rocketmq.read.topic";
	public static final String RECEIVER_MQ_GROUP = "receiver.rocketmq.group";

	public static final String HANDLER_THREAD_NUM = "handler.thread.num";
	public static final String HANDLER_QUEUE_SIZE = "handler.queue.size";

	public static final String DEDUPLICATION_NECESSARY = "deduplication.necessary";
	public static final String DEDUPLICATION_URL = "deduplication.url";
	public static final String DEDUPLICATION_FIELDS = "deduplication.fields";
	public static final String DEDUPLICATION_PREFIX = "deduplication.prefix";
	public static final String DEDUPLICATION_SEND_TOPIC = "deduplication.send.topic";

	public static final String SEND_QUEUE_BATCH_NUM = "send.queue.batch.num";
	public static final String SEND_QUEUE_TIME_OUT = "send.queue.time.out";
}
